from common.kafka import *


hosts = "10.10.202.13:9092"
topic = "mb.park.in"
group = "ywpt_monitor_park"
interval_minutes = 1
data = get_kafka_data(hosts, topic, group, interval_minutes)
res = get_kafka_data()